<?php
include_once (dirname(__FILE__) . '/../../init.php');

class EmailSender extends QueueConsumer {
  protected function worker($data) {
    Email::direct_send($data['to'], $data['subject'], $data['body']);
    $this->log("Email Sent to :{$data['to']}, Subject:{$data['subject']}");
  }
}

(new EmailSender())->doWorker();